package org.tao.lightningmq.common.transaction;

import org.tao.lightningmq.common.dto.MessageDTO;
import org.tao.lightningmq.common.enums.LocalTransactionState;

public interface TransactionListener {

    /**
     * 执行本地事务逻辑处理的回调函数
     *
     * @param messageDTO
     * @return
     */
    LocalTransactionState executeLocalTransaction(MessageDTO messageDTO);

    /**
     * 事务消息从broker回调到本地的回调接口
     *
     * @param messageDTO
     * @return
     */
    LocalTransactionState callBackHandler(MessageDTO messageDTO);

}
